package site.teamo.biu.flink.function.sink;

import site.teamo.biu.flink.sdk.annotation.function.BFSinkFunction;
import site.teamo.biu.flink.sdk.function.AbstractSinkFunction;
import site.teamo.biu.flink.sdk.job.JobContext;

/**
 * @author haocongshun
 * @date 2023/07/25 15:21:27
 */
@BFSinkFunction
public class ConsolePrintSink<T> extends AbstractSinkFunction<T> {
    public ConsolePrintSink(String name, JobContext context) {
        super(name, context);
    }

    @Override
    public void invoke(T value, Context context) throws Exception {
        System.out.println(value);
    }
}
